package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils
import org.apache.flink.api.scala._
/**
 *
 *
 * @author ydl
 * @since 2020/10/14
 */
object FirstNDemo extends App with Utils {
  val input = env.fromCollection(1 to 100)
  input.print()
  input.first(10).print()
}
